#include "../mqserver/mq_channel.hpp"

int main()
{
    pprmq::ChannelManager::ptr cmp = std::make_shared<pprmq::ChannelManager>();

    cmp->openChannel("c1", 
        muduo::net::TcpConnectionPtr(),
        pprmq::ProtobufCodecPtr(),
        std::make_shared<pprmq::ConsumerManager>(),
        threadpool::ptr(),
        std::make_shared<pprmq::VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"));
    return 0;
}